package com.qzuser.sendmessagebasic.server.queue;

import com.qzuser.sendmessagebasic.common.exception.BrokerException;
import com.qzuser.sendmessagebasic.common.exception.ConsumeException;
import com.qzuser.sendmessagebasic.common.exception.ToolException;
import com.qzuser.sendmessagebasic.server.message.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {
    void handleDelivery(String consumerTag, BasicProperties properties, byte[] body) throws ConsumeException, ToolException, IOException, BrokerException;
}
